ConcurrentStatelessSubjectAsync class¶

Defined in

Namespace: ReactiveUI.Extensions.Async.Subjects Assembly: ReactiveUI.Extensions.dll Full name: ReactiveUI.Extensions.Async.Subjects.ConcurrentStatelessSubjectAsync<T> Modifiers: public sealed

Summary¶

View source

        Represents a stateless asynchronous subject that forwards notifications to observers concurrently.

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481

Class hierarchy

classDiagram
class ConcurrentStatelessSubjectAsync~T~
class BaseStatelessSubjectAsync~T~
BaseStatelessSubjectAsync~T~ <|-- ConcurrentStatelessSubjectAsync~T~

Inherits from: BaseStatelessSubjectAsync

Remarks¶

This subject distributes notifications to all subscribed observers in parallel, allowing for improved throughput in scenarios where observer processing can occur independently. Use this type when observer notification order is not important and concurrent delivery is desired. Thread safety is ensured for concurrent observer notifications.

Constructors¶

Name	Summary
.ctor

Methods¶

Name	Summary
OnNextAsyncCore	Asynchronously notifies all observers in the collection with the specified value.
OnErrorResumeAsyncCore	Notifies all specified observers of an error and resumes processing asynchronously.
OnCompletedAsyncCore	Notifies all observers that the asynchronous operation has completed, forwarding the specified result to each observer.

Inherited members